from x_com import xport_core
from x_com.import_api import ecommerce_data_source_service_0_0_1
logger = xport_core.getLogger()
# ProductSale
async def product_sale(ctx: xport_core.Context, param: ecommerce_data_source_service_0_0_1.ProductSaleInfo):
  logger.info("接收 product_sale 数据。。。")

# UserRegister
async def user_register(ctx: xport_core.Context, param: ecommerce_data_source_service_0_0_1.UserInfo):
  logger.info("接收 user_register 数据。。。")

# UserLogin
async def user_login(ctx: xport_core.Context, param: ecommerce_data_source_service_0_0_1.UserLoginInfo):
  logger.info("接收 user_login 数据。。。")

